#!/usr/bin/python
# coding:utf-8

# @FileName:    main.py
# @Time:        2024/5/13 22:27
# @Author:      hean
# @Project:     Intelligent_reply_generation_service
# @Introduction：   该工程主要用于从消息队列获取采集到的用户弹幕，生成智能回复，并存入回复生成的kafka队列。

from generate_reply import KafkaConsumer
if __name__ == '__main__':
    kafka_consumer = KafkaConsumer()
    kafka_consumer.start_consuming()
